package com.xiaotu.spider.pipeline;

import org.springframework.stereotype.Component;
import us.codecraft.webmagic.ResultItems;
import us.codecraft.webmagic.Task;
import com.xiaotu.common.model.TvScoreModel;
import com.xiaotu.common.util.Constants;
import com.xiaotu.common.util.DataRedisKeyUtils;
import com.xiaotu.spider.APipeline;

/**
 * 
 * 项目名称：Sprider-WebMagic    
 * 类名称：TvScorePipeline    
 * 类描述：剧网站评分    
 * 创建人：张晓   
 * 创建时间：2020年3月23日 下午2:46:47    
 * @version
 */
@Component("TvScorePipeline")
public class TvScorePipeline extends APipeline
{
	@Override
	protected void doProcess(ResultItems resultItems, Task task)
	{
		TvScoreModel tv = resultItems.get(TvScoreModel.class.getName());
		if (tv == null)
			return;
		String key = DataRedisKeyUtils
				.getKey(Constants.DataRedisKey.TV_SCORE_YYYYMMDD);
		cacheHandler.hSet(key, tv.getId()+"_"+tv.getTvname()+"_"+tv.getSiteName(),tv);
		cacheHandler.setCacheTimeout(key);
	}
}